package cn.lgwen.candy.runtime.operator;

/**
 * 2019/12/24
 * aven.wu
 * danxieai258@163.com
 * O type of out data
 * 每个sourceOperator 都会在独立的线程中运行
 */
public abstract class SourceOperator<O> extends AbstractOperator {

    /**
     * create
     */
    public abstract void run(Fetcher<O> fetcher);


    public abstract void cancel();
}
